package com.omuao.cloud.stabilization.common.message.core;

import com.omuao.cloud.stabilization.common.message.core.metadata.MessageQueueData;

/**
 * 消息发送者
 *
 * @author yumi
 */
public interface MessageProducer {

    /**
     * 发送消息服务
     *
     * @param topic       主题
     * @param tag         标签
     * @param contentType 内容类型
     * @param message     消息内容
     * @return true 发送成功 false 发送失败
     */
    boolean send(String topic, String tag, String contentType, Object message);

    /**
     * 发送消息服务
     *
     * @param queueData 队列数据
     * @return true 发送成功 false 发送失败
     */
    boolean send(MessageQueueData queueData);

}
